package io.gitee.milklynk;

import io.gitee.milklynk.vo.response.ChatResponse;

import java.util.concurrent.Executor;
/** */
public interface StreamCallback {
    /**
     * 收到单条消息
     * @param response chat响应体
     */
    void onResponse(ChatResponse response);

    /**
     * 流式传输结束
     */
    void onComplete();

    /**
     * 发生错误
     * @param e 异常对象
     */
    void onError(Exception e);

    /**
     * 回调时使用的线程,null表示使用默认线程
     * @return Executor
     */
    default Executor getExecutor() {
        return null;
    }
}
